package com.Lixiaoqian.PartyHistoryMuseum.utils;

import android.os.AsyncTask;
import android.util.Log;
import android.widget.TextView;

import com.Lixiaoqian.PartyHistoryMuseum.bean.BannerBean;
import com.Lixiaoqian.PartyHistoryMuseum.ui.ArCamActivity;
import com.Lixiaoqian.PartyHistoryMuseum.ui.LoadActivity;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Enumeration;
import java.util.zip.ZipEntry;
import java.util.zip.ZipException;
import java.util.zip.ZipFile;


public class ZipExtractorTask extends AsyncTask<Void, Integer, Long>  {
    private final String TAG = "ZipExtractorTask";
    private final File mInput;
    private final File mOutput;
    private int mProgress = 0;
    private final LoadActivity mContext;
    private boolean mReplaceAll=true;
    private TextView textView_info;//按钮关闭页面
    private BannerBean bean;
    public ZipExtractorTask(String in, String out, LoadActivity context, TextView textView_info, BannerBean bean){
        super();
        mInput = new File(in);
        mOutput = new File(out);
        if(!mOutput.exists()){
            if(!mOutput.mkdirs()){
                Log.e(TAG, "Failed to make directories:"+mOutput.getAbsolutePath());
            }
        }
        mContext = context;
        this.bean=bean;
        this.textView_info=textView_info;
    }
    @Override
    protected Long doInBackground(Void... params) {
        // TODO Auto-generated method stub
        if (isCancelled()){
            return null;
        }
        return unzip();
    }
    @Override
    protected void onPostExecute(Long result) {
        if(isCancelled())
            return;
        textView_info.setText("解压完成");
        mContext.finish();
        //页面进行跳转
        ArCamActivity.launch(mContext);
        PrefUtils.putString(Constant.PRE_ZIP_DATA,bean.getCreate_date(),mContext);
    }
    @Override
    protected void onPreExecute() {
    }
    @Override
    protected void onProgressUpdate(Integer... values) {
    }

    /**
     * 解压文件实现
     * @return
     */
    private long unzip(){
        long extractedSize = 0L;
        Enumeration<ZipEntry> entries;
        ZipFile zip = null;
        try {
            zip = new ZipFile(mInput);
            long uncompressedSize = getOriginalSize(zip);
            publishProgress(0, (int) uncompressedSize);
            entries = (Enumeration<ZipEntry>) zip.entries();
            while(entries.hasMoreElements()){
                ZipEntry entry = entries.nextElement();
                if(entry.isDirectory()){
                    continue;
                }
                File destination = new File(mOutput, entry.getName());
                if(!destination.getParentFile().exists()){
                    Log.e(TAG, "make="+destination.getParentFile().getAbsolutePath());
                    destination.getParentFile().mkdirs();
                }
                if(destination.exists()&&mContext!=null&&!mReplaceAll){
                }
                ProgressReportingOutputStream outStream = new ProgressReportingOutputStream(destination);
                extractedSize+=copy(zip.getInputStream(entry),outStream);
                outStream.close();
            }
        } catch (ZipException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            try {
                if (zip!=null)
                zip.close();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        return extractedSize;
    }
    private long getOriginalSize(ZipFile file){
        Enumeration<ZipEntry> entries = (Enumeration<ZipEntry>) file.entries();
        long originalSize = 0l;
        while(entries.hasMoreElements()){
            ZipEntry entry = entries.nextElement();
            if(entry.getSize()>=0){
                originalSize+=entry.getSize();
            }
        }
        return originalSize;
    }

    /**
     * 输出到本地
     * @param input
     * @param output
     * @return
     */
    private int copy(InputStream input, OutputStream output){
        byte[] buffer = new byte[1024*8];
        BufferedInputStream in = new BufferedInputStream(input, 1024*8);
        BufferedOutputStream out  = new BufferedOutputStream(output, 1024*8);
        int count =0,n=0;
        try {
            while((n=in.read(buffer, 0, 1024*8))!=-1){
                out.write(buffer, 0, n);
                count+=n;
            }
            out.flush();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            try {
                out.close();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            try {
                in.close();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        return count;
    }

    private final class ProgressReportingOutputStream extends FileOutputStream{
        public ProgressReportingOutputStream(File file)
                throws FileNotFoundException {
            super(file);
            // TODO Auto-generated constructor stub
        }
        @Override
        public void write(byte[] buffer, int byteOffset, int byteCount)
                throws IOException {
            // TODO Auto-generated method stub
            super.write(buffer, byteOffset, byteCount);
            mProgress += byteCount;
            publishProgress(mProgress);
        }
    }

}